package org.cancer.app

import org.apache.spark.streaming.dstream.DStream
import org.cancer.bean.CancerTypeDeathData_Faye
import org.cancer.common.TApp_Faye
import org.cancer.controller.CancerTypeDeathController_Faye
import org.cancer.handler.DataHandler_Faye

object CancerTypeDeathApp_Faye extends TApp_Faye{

  val cancerTypeDeathController_Faye = new CancerTypeDeathController_Faye()
  start("local[*]","CTDApp"){
    val data: DStream[CancerTypeDeathData_Faye] = DataHandler_Faye.KafkaDataHandler("BD2", "CancerTypeDeath")
    cancerTypeDeathController_Faye.dispatch(data)
    DataHandler_Faye.startAndAwait()
  }
}
